package xqp.mq._04_direct;

import com.rabbitmq.client.*;

import java.io.IOException;
import java.util.concurrent.TimeoutException;

/**
 *  广播模式  只要绑定了交换机队列都会接收到
 * 消费者的步骤
 * 1：创建连接
 * 2：创建通道
 * 3：创建队列
 * 4：绑定交换机
 * 5：消息处理回调
 * 6：签收消息
 */

// 消费者
class Consumer1 {

    // 创建队列常量
    public static final String NAME_QUEUE_DIRECT_CONSUMER1 = "NAME_QUEUE_DIRECT_CONSUMER1";

    public static void main(String[] args) throws IOException, TimeoutException {
        //创建连接
        ConnectionFactory factory = new ConnectionFactory();
        Connection connection = factory.newConnection();

        // 创建通道
        Channel channel = connection.createChannel();

        // 消费者谁先处理完就给当前消费者
        channel.basicQos(1);

        // 创建队列
        channel.queueDeclare(NAME_QUEUE_DIRECT_CONSUMER1 // 队列的名字
                , true // 是否持久化
                ,false // 是否独占连接
                ,false // 是否自动删除
                ,null ); // 其他属性

        // 绑定交换机
        channel.queueBind(NAME_QUEUE_DIRECT_CONSUMER1, // 第一个参数是你要绑定的队列
                            Producer.NAME_EXCHANGE_DIRECT, // 第二个参数是要将队列绑定到的交换机
                            "error"); //   第三个参数是routing key 通过error来找到交换机传送信息
        // 消息处理回调
        Consumer callback =new DefaultConsumer(channel){
            @Override
            public void handleDelivery(String consumerTag,
                                       Envelope envelope, // 信封
                                       AMQP.BasicProperties properties,
                                       byte[] body) throws IOException {
                System.out.println("消息收到了"+new String(body));
                //int i =1/0;// 这里报了错但是我没签收
                System.out.println("consumerTag = " + consumerTag);
                System.out.println("交换机 = "+envelope.getExchange());
                System.out.println("队列 = "+envelope.getRoutingKey());
                System.out.println("消息的id = "+envelope.getDeliveryTag());
                System.out.println("消息消费完毕");
                // 手动签收消息
                channel.basicAck(envelope.getDeliveryTag() // 消息的id
                        ,false ); // 是否签收多个消息
            }
        };
        //监听队列
        channel.basicConsume(NAME_QUEUE_DIRECT_CONSUMER1, //我们要监听哪个队列
                false, // 是否自动签收   自动签收会出现 如果消息消费失败，可能会导致消息丢失
                callback ); // 处理消息回调
    }
}
